package io.gitee.kenewstar.dbmq.handler;

import io.gitee.kenewstar.dbmq.ConsumerRegisterInfo;
import io.gitee.kenewstar.dbmq.ConsumerTask;

import java.util.List;

/**
 * @author kenewstar
 */
public interface DbMqRegisterHandler {

    void initRegisterInfo();

    void initQueueInfo(List<ConsumerTask> taskList);

    void registerConsumer(List<ConsumerTask> taskList);

    List<ConsumerRegisterInfo> pullRegisterUpdate(List<ConsumerTask> taskList) ;

}
